package com.zxq.ruoyi.network.tcp.modbus;




import org.apache.commons.lang3.StringUtils;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

/**
 *  为了获取通道
 */
public class ModBusChannelContainer {


    /**
     * 容器控制
     */
    static ConcurrentMap<String, ModBusService> modbusContainer = new ConcurrentHashMap<>();


    /**
     * 放置modbus 数据
     * @param devId 设备编号
     * @param modBusCrc 数据
     */
    public static void putModBusCrc(String devId, ModBusService modBusCrc) {
        modbusContainer.put(devId,modBusCrc);
    }

    /**
     * 获取modbus数据
     * @param devId 设备编号
     */
    public static ModBusService getModbusCrc(String devId) {

        if(StringUtils.isNotEmpty(devId)) {
            return modbusContainer.get(devId);
        }

        return null;
    }




}
